package org.sunrise.game.game.message;

import org.sunrise.game.common.log.LogCore;
import org.sunrise.game.rpc.message.RpcClientMessageManager;

/**
 * game rpc消息处理类
 * 此线程只负责发送rpc
 * 收到的rpc返回数据会放到HumanObjectManger.callBackQueue队列
 */
public class GameRpcMessageManager extends RpcClientMessageManager {

    public GameRpcMessageManager(String nodeId) {
        super(nodeId);
    }

    @Override
    public void pulse() {
        try {
            pulseSender();
        } catch (Exception e) {
            LogCore.Server.error("DispatchThread pulse, error : { {} }", e.getMessage());
        }
    }
}
